package com.smartboot.plus.plugins.proxy;

import com.smartboot.plus.plugins.AbstractFeature;
import org.smartboot.socket.extension.plugins.ProxyProtocolPlugin;
import tech.smartboot.mqtt.plugin.spec.BrokerContext;

public class MqttProxyProtocolPlugin extends AbstractFeature {


	public MqttProxyProtocolPlugin(BrokerContext context) {
		super(context);
	}

	@Override
	public String name() {
		return "proxy";
	}

	@Override
	public void start() throws Exception {
		context.Options().addPlugin(new ProxyProtocolPlugin<>());
	}
}
